package com.qsl.datax.plugin.writer.kafkawriter;

public class Key {

    public static final String BOOTSTRAP_SERVERS="bootstrapServers";

    // must have
    public static final String TOPIC = "topic";

    public static final String ACK = "ack";

    public static final String BATCH_SIZE = "batchSize";

    public static final String RETRIES = "retries";

    public static final String KEY_SERIALIZER = "keySerializer";

    public static final String VALUE_SERIALIZER = "valueSerializer";

    // not must , not default
    public static final String FIELD_DELIMITER = "fieldDelimiter";

    public static final String NO_TOPIC_CREATE = "noTopicCreate";

    public static final String TOPIC_NUM_PARTITION = "topicNumPartition";

    public static final String TOPIC_REPLICATION_FACTOR = "topicReplicationFactor";

    public static final String WRITE_TYPE= "writeType";

    public static final String SASL = "sasl";
    public static final String SASL_SECURITY_PROTOCOL = "securityProtocol";
    public static final String SASL_MECHANISM = "mechanism";
    public static final String SASL_USERNAME = "username";
    public static final String SASL_PASSWORD = "password";

    public static final String COLUMN = "column";
}
